package com.wpen.unit.core;

import java.util.concurrent.TimeUnit;

import com.wpen.unit.AppVariables;

import lombok.extern.slf4j.Slf4j;

/**
 * 在线工作线程，等待处理
 *
 * @author Wang Peng
 * @date 2022年12月12日
 * 
 */
@Slf4j
public class ZyxWorker {
    private int checkMax = 120;
    private int checkNum = 0;

    public void checkAppStarted() {
        while (!AppVariables.kernelStarted) {
            try {
                TimeUnit.MILLISECONDS.sleep(1000);
                checkNum++;
                if (checkNum > checkMax / 2) {
                    log.warn("Application startup exception !!! ");
                }
            } catch (InterruptedException e) {
                log.error(e.getMessage(), e);
            }
        }
    }
}
